//package com.qiangqiang.task.server.message;
//
//import com.qiangqiang.task.common.utils.JsonUtil;
//import com.qiangqiang.task.server.entity.ReceviedTask;
//import com.qiangqiang.task.server.mapper.ReceviedTaskMapper;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.rabbit.annotation.Queue;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
///**
// * @author : sky
// * @date : 2018/7/28
// * @description : 消息队列接收者
// */
//@Slf4j
//@Component
//public class MqRecevier {
//
//    @Autowired
//    private ReceviedTaskMapper receviedTaskMapper;
//
//    @RabbitListener(queuesToDeclare = @Queue("task"))
//    public void createReceviedTask(String message) {
//        ReceviedTask task=JsonUtil.stringTobean(message,ReceviedTask.class);
//        log.info("message:{}",task);
//        receviedTaskMapper.insertReceviedTask(task);
//    }
//}
